package com.demo.rabbitmq.demo.simplest;

import com.demo.rabbitmq.util.RabbitMQUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Producer {

    static  final  String QUUE_NAME="simple_queue";

    public static void main(String[] args) throws IOException, TimeoutException {
        Connection connection = RabbitMQUtil.getConnection();
        //创建频道
        Channel channel = connection.createChannel();
        //创建列队 参数1：列队名称 参数2：是否支持化队列 参数3：是否独占本次链接 参数4：是否在不使用的时候自动删除列队 参数5：列队其他 参数
        channel.queueDeclare(QUUE_NAME,true,false,false,null);

        System.out.println("OK");

        for ( int i=1;i<30;i++){

            String messageStr="消息："+i;
            channel.basicPublish("",QUUE_NAME,null,messageStr.getBytes());
        }

        channel.close();
        connection.close();


    }
}
